
package cn.hz.horse;

import java.io.Serializable;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

 

public class EzSuccRuner  extends Thread{
 
	protected  LinkedBlockingQueue succQu; 
	
	 
	private EzResHandle handle;
	private int timeouts=0;
	boolean isRunning=true;
	@Override
	public void run(){
	   while (isRunning) {
           try {
        	   Object obj=succQu.take();
        	   handle.handleSucc(obj);
           } catch (Exception e) {
               e.printStackTrace();    
           }
       }
   }

	 

 
 
	 




	public LinkedBlockingQueue getSuccQu() {
		return succQu;
	}










	public void setSuccQu(LinkedBlockingQueue succQu) {
		this.succQu = succQu;
	}










	public boolean isRunning() {
		return isRunning;
	}

	public void setRunning(boolean isRunning) {
		this.isRunning = isRunning;
	}

	public EzResHandle getHandle() {
		return handle;
	}

	public void setHandle(EzResHandle handle) {
		this.handle = handle;
	}

	

	public int getTimeouts() {
		return timeouts;
	}

	public void setTimeouts(int timeouts) {
		this.timeouts = timeouts;
	} 
	
	
	
	
}
